Amazon SNSをColdFusion10とAWS SDK for javaの組み合わせで操作する #2 | publish

ColdFusion × AWS SDK for java

#Adobe ColdFusion

#Java

#AWS SDK for Java

#Adobe

#AWS SDK

津熊弘和

2013.08.22

この記事は公開されてから1年以上経過しています。情報が古い可能性がありますので、ご注意ください。

前回はsubscribeまでを体験しましたので、今回はpublishを実際にやってみます。

動作させた環境

Windows7 64Bit
ColdFusion10 デベロッパー版
AWS SDK for java 1.5.3

Amazon SNSを使う（publish）

AWS SDK for java 1.5.4が既にリリースされていますが、1.5.3で検証を続けることにします。
AWS SDK for java 1.5.4では新しいmethodであるsetTargetArnが追加されていますが、そのmethodは使わずにpublishの検証を進めたいと思います。

手順

トピックのあるリージョンを設定
メッセージの設定
このメッセージが発行されたトピックのARNの設定
publishAPIをコール

今回実行したpublishのサンプルソースは以下の通りです（ aws_sns_publish.cfm ）

<cfcontent type="text/html; charset=utf-8">
<cfprocessingdirective pageEncoding="utf-8" suppressWhitespace="true">

<cflock scope = "Session" timeout = "30" type = "Exclusive">
    <cfset aws_AK = #accessKeyId#>
    <cfset aws_SK = #secretAccessKey#>
</cflock>

<cfoutput>
<html lang="ja">
<head>
    <meta charset="utf-8">
    <title>Coldfusion + AWS SDK for java SNS publish Sample</title>
</head>

<body>

<cfset awscreds = createObject("java","com.amazonaws.auth.BasicAWSCredentials").init(aws_AK,aws_SK)>
<cfset SNSClient = createObject("java","com.amazonaws.services.sns.AmazonSNSClient").init(awscreds)>

<!--- RegionをEUに指定 --->
<cfset sns_region = SNSClient.setEndPoint("https://sns.eu-west-1.amazonaws.com/")>

<!--- 初期化 --->
<cfset SNSPublishRequest = createObject("java","com.amazonaws.services.sns.model.PublishRequest").init()>
<cfset snstest = SNSPublishRequest.setMessage("aws sns sample publish message from Coldfusion10!")>
<!--- aws sdk for java 1.5.4 からは setTargetArn というmethod が追加されていました --->
<!--- Management Console にログインしてSNSのTOPICを確認してpublish対象となるTopic ARNを指定します。
      arn:aws:sns:eu-west-1:xxxxxxxxxxxx:tsukumaTOPIC の様にTopic ARNはなっています。 --->
<cfset snstest = SNSPublishRequest.setTopicArn("ここにはTopic ARNを指定します。")>

<!--- publishする --->
<cfset sns_publish_test = SNSClient.publish(SNSPublishRequest)>

<!--- 確認用にAmazon Resource Name(ARN)を表示させる --->
<cfdump var="#snsres.getTopicArn()#">

</cfoutput>
</cfprocessingdirective>      
<cfsetting enablecfoutputonly="false">

</body>
</html>

上記のテンプレートを実行した後、下記の様なメールが到着します。

CFMLテンプレート内で指定したメッセージ内容の【 aws sns sample publish message from Coldfusion10! 】が正しくセットされてメール通知されていることが確認できました。

せっかくなので通知先をSQSにしてみましょう。SQSへの通知は無料なのでお得？
前回使ったCFMLテンプレート( aws_sns_createtopic.cfm )で『通知先をemailで設定する場合』という部分の2行をコメントにしてSQSにする行を追加します。


<!--- 通知先をemailで設定する場合 --->
<!---
<cfset snstest = SQSsubscribeRequest.setProtocol("email")>
<cfset snstest = SQSsubscribeRequest.setEndpoint("プッシュ通知したいメールアドレスを指定")>
--->

<!--- 通知先をSQSで設定する場合 --->
<cfset snstest = SNSsubscribeRequest.setProtocol("sqs")>
<!--- Management Consoleにログインして前回使用したキューを確認してそのキューのARNを指定します。 --->
<!--- arn:aws:sqs:eu-west-1:xxxxxxxxxxxx:tsukuma-SQSTest のようなARNになっているかと思います --->
<cfset snstest = SNSsubscribeRequest.setEndpoint("ここは通知したいキューのARNを指定します")>

前回EMail通知用で aws_sns_createtopic.cfm を実行して作成されたTOPICとSubscriptionは削除します。
1で不要なものを削除してから、SQSに通知先を変えた状態の aws_sns_createtopic.cfm のテンプレートを実行します。
aws_sns_publish.cfm を再度実行してpublishします。

SQSに通知先を設定した場合でSNSのTopic OwnerとSQSのQueue Ownerが同じ場合はsubscribeの確認ステップが省略されるのでそのままPendingConfirmationにならずに購読完了状態になります。また下記スクリーンショットでProtocolがSQSになっていることも確認できます。